package com.sqllog.config;

import lombok.Getter;
import lombok.Setter;

import java.io.Serializable;
import java.util.LinkedHashSet;
import java.util.Set;

/**
 * canalServer 实例
 *
 * @author chennengcheng
 * @date 2022-01-07 14:24
 * @remark
 */

@Getter
@Setter
public class CanalClientConfig implements Serializable {

    /**
     * 实例名称
     */
    private String instanceName;

    /**
     * 是否是集群模式
     */
    private boolean clusterEnabled;

    /**
     * zookeeper 地址
     */
    private Set<String> zookeeperAddress = new LinkedHashSet<>();

    /**
     * canal 服务器地址，默认是本地的环回地址
     */
    private String host = "127.1.1.1";

    /**
     * canal 服务设置的端口，默认 11111
     */
    private int port = 11111;

    /**
     * 集群 设置的用户名
     */
    private String userName = "";

    /**
     * 集群 设置的密码
     */
    private String password = "";

    /**
     * 批量从 canal 服务器获取数据的最多数目
     */
    private int batchSize = 1000;

    /**
     * 是否有过滤规则
     */
    private String filter;

    /**
     * 信息消费线程数
     */
    private int consumerThreadSize = 5;
}
